package xman.com.xmancloudserver.kafka;

import org.springframework.stereotype.Component;

//创建一个类
@Component
public class TopicHandler {
    private final static String TOPIC_NAME = "my-replicated-topic";
    String[] KAFKA_TOPICS = {"xman", "login", "client"};

    //调用此方法获取topic参数，参数从哪来自己在方法里实现
    public String[] getTopics() {
        return KAFKA_TOPICS;
    }

    public String getTopic() {
        return TOPIC_NAME;
    }
}
